package avicit.bdp.dcs.datasource.service.ds;


import avicit.bdp.dcs.utils.JdbcConstants;

public class KafkaDS extends BaseDS {

    /**
     * @return type
     */
    @Override
    public String type() {
        return JdbcConstants.KAFKA;
    }

    /**
     * 判断是否支持结构化采集
     *
     * @return
     */
    @Override
    public boolean isSupportStructCollection() {
        return false;
    }

    /**
     * 判断是否支持半结构化采集
     *
     * @return
     */
    @Override
    public boolean isSupportSemiStructCollection() {
        return false;
    }

    /**
     * 判断是否支持流式采集
     *
     * @return
     */
    @Override
    public boolean isSupportStreamCollection() {
        return true;
    }

    /**
     * 判断是否支持API采集
     *
     * @return
     */
    @Override
    public boolean isSupportAPICollection() {
        return false;
    }

    /**
     * 判断是否需要用户名和密码
     *
     * @return
     */
    @Override
    public boolean needUserAndPassword() {
        return false;
    }

    /**
     * 获取数据源名称
     *
     * @return datasource
     */
    @Override
    public String getDatasource() {
        return JdbcConstants.KAFKA;
    }

    /**
     * 获取数据源驱动类
     *
     * @return jdbcDriverClass
     */
    @Override
    public String getJdbcDriverClass() {
        return null;
    }

}
